package com.github.yoojia.mqtt.boot;

import com.github.yoojia.mqtt.MQTTSocket;
import com.github.yoojia.mqtt.Message;

/**
 * 响应式消息执行器
 * @author Yoojia Chen (yoojiachen@gmail.com)
 * @since 1.0.0
 */
public interface PubSubActuator extends Actuator {

    void onEvent(MQTTSocket socket, Message event);
}
